﻿using Contracts;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace EventBus
{
    public class InProcEventBus : IEventBus
    {
        public InProcEventBus()
        {
            this.events = new List<IEvent>();
        }

        public void Add(IEvent @event)
        {
            this.events.Add(@event);
        }

        public IDisposable Subscribe(IObserver<IEvent> observer)
        {
            throw new NotImplementedException();
        }

        private List<IEvent> events;
    }
}
